MyKafkaStreamsConfiguration

@Configuration(proxyBeanMethods = false)
@EnableKafkaStreams
open class MyKafkaStreamsConfiguration

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open fun kStream(streamsBuilder: StreamsBuilder): KStream<Integer, String>